package com.example.demo.msg;

import cn.hutool.json.JSONUtil;
import com.example.demo.annotation.Topic;
import com.example.demo.cons.Pattern;
import com.example.demo.emqx.SuperConsumer;
import com.example.demo.model.User;
import org.eclipse.paho.client.mqttv3.MqttMessage;

/***************************************************************************
 * <pre></pre>
 * @文件名称： ConnectMsg.java
 * @包 路   径：  com.example.demo.emqx
 * @版权所有：北京数字医信科技责任有限公司 (C) 2021
 *
 * @类描述:
 * @版本: V1.0
 * @创建人： guozhaolong
 * @创建时间：2021-12-02 21:01
 * @修改记录：
 */
@Topic(topic = "client:report:1", patten = Pattern.SHARE)
public class ConnectMsg extends SuperConsumer<User> {

    @Override
    public User decoder(MqttMessage msg) {
        return JSONUtil.toBean(new String(msg.getPayload()), User.class);
    }

    @Override
    protected void msgHandler(String topic, User entity) {

    }
}
